package com.example.myesstudy.es_sql;

import org.elasticsearch.xpack.sql.jdbc.EsDriver;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

/**
 *  图灵学院-白起老师   有问题 https://www.cnblogs.com/hts-technology/p/9282421.html  需要什么白金许可证
 * 使用JDBC来操作ES
 */
public class JdbcExample {
    public static void main(String[] args) throws Exception {
        // 1. 加载ES驱动
        Class.forName(EsDriver.class.getName());

        // 2. 建立连接
        String coon="jdbc:es://http://127.0.0.1:9200";
        Connection connection = DriverManager.getConnection(coon);

        // 3. 准备SQL语句
        String sql = "SELECT * FROM job_index limit 10";

        // 4. 使用PreparedStatement执行SQL
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        ResultSet resultSet = preparedStatement.executeQuery();

        // 5. 遍历结果
        while(resultSet.next()) {

            String jd=resultSet.getString("jd");
            String title=resultSet.getString("title");

            System.out.println("职位：" + jd + " 标题：" + title);
        }

        // 6. 关闭连接
        resultSet.close();
        connection.close();
    }
}
